package com.xdf.ecommerce.source;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 自定义物流消息通信信道
 * @author chanchaw
 * @create 2025-11-13 12:56
 */
public interface LogisticsSource {
    // 保证等于配置文件中的 spring.cloud.stream.bindings 下的 key = logisticsOutput
    // 在 kafka 中使用该自定义信道发送消息，消费消息
    String CHANNEL_NAME = "logisticsOutput";

    // 指定使用本接口中上面硬编码的通信信道
    @Output(LogisticsSource.CHANNEL_NAME)
    MessageChannel logisticsOutput();
}
